package org.jeecg.modules.syncdata.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.jeecg.modules.syncdata.entity.SyncCompensate;

import java.util.List;

/**
 * 同步补偿映射器
 *
 * @author zhanglei01
 * @date 2022/03/16
 */
@Mapper
public interface SyncCompensateMapper extends BaseMapper<SyncCompensate> {

    /**
     * 获取同步数据通过分片
     *
     * @param shardIndex 碎片索引
     * @param shardTotal 碎片总
     * @param pageSize   分页大小
     * @return {@link List}<{@link SyncCompensate}>
     */
    List<SyncCompensate> getSyncDataBySharding(Integer shardIndex, Integer shardTotal, Integer pageSize);

}
